package com.zhaosc.spark

import org.apache.spark.SparkConf
import org.apache.spark.SparkContext

object WXLogAnalysis {
  
  def main(args: Array[String]) {
//    val conf = new SparkConf().setAppName("wxlog")
//      .setMaster("local");
//    val sc = new SparkContext(conf);
//    val line = sc.textFile("data1.txt");
//    line.filter(_.startsWith("WXAClickLog4Analysis"))
//      .map(c => {
//        val arr = c.split(",")
//        print(arr)
//      });
//
//    sc.stop()
    
    

  }

}